/*
 ***************************************************************************************
 * All rights Reserved, Designed By RTF
 * @Title:  KafkaConsumerProperties.java   
 * @Package com.rtf.repair.mq.kafka.consumer
 * @Description: 消费者属性   
 * @author: 司福林
 * @date:   2020-10-17 17:27:05   
 * @version V1.0 
 * @Copyright: 2020 RTF. All rights reserved.
 * 注意：本内容仅限于公司内部使用，禁止外泄以及用于其他的商业目
 *  ---------------------------------------------------------------------------------- 
 * 文件修改记录
 *     文件版本：         修改人：             修改原因：
 ***************************************************************************************
 */
package com.rtf.framework.mq.kafka.consumer;

import lombok.Data;

/**
 * Instantiates a new kafka consumer properties.
 */
@Data
public class KafkaConsumerProperties {

	/** 启用kafka消费 */
	private boolean enable = false;

	/** boker 地址，用“,”间隔 */
	private String servers;

	/** 拉取最大记录数 */
	private int maxPollRecords = 500;

	/** 最大拉取数据间隔数，ms */
	private int maxPollInterval = 300000;

	/** 会话超时时间，ms*/
	private int sessionTimeout = 10000;

	/** 心跳间隔，ms */
	private int heartbeatInterval = 3000;

	/** 自动提交偏移量间隔，ms */
	private int autocommitInterval = 5000;

	/** 最大读取数据字节数 */
	private int fetchMaxBytes = 50 * 1024 * 1024;

}
